package com.paho.handler;

import java.util.Set;

/**
 *  分发处理器接口
 * @Author wdy
 * @Date 2023/9/19
 **/
public interface MqttDistribute {

    /**
     * 将处理器Bean设置到消息分发处理器中
     * @param topic             话题
     * @param mqttHandler       消息处理器
     */
    public void putHandlerBean(String topic ,MqttHandler mqttHandler);

    /**
     * 获取需要处理的主题(所有注册的主题)
     * @return
     */
    public Set<String> getTopics();

    /**
     * 处理消息
     * @param topic     话题
     * @param message   消息
     */
    public void distribute(String topic, String message);

}
